package com.mck.service;

import reactor.core.publisher.Flux;

public interface AiReactiveService {
  Flux<String> processAiRequestReactive(String message);
}